#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include "process_ipc_shm_msg.h"

int main(void)
{
    char buff[64] = {0};
    int count = 0;
    void *queue = queue_create("/test", 64, 5);
    if (queue == NULL)
    {
        printf("create queue failed\n");
        return -1;
    }
    //queue_fixup(queue);
    while (1)
    {
        memset(buff, 0x00, sizeof(buff));
        sprintf(buff, "hello %d\n", count++);
        queue_send(queue, buff, strlen(buff) + 1);
        sleep(1);
    }
    return 0;
}